
import java.util.ArrayList;

import twitter4j.Tweet;

public class ImportaTweets extends Thread
{
	public TwitterHelper twitterHelper;
	public BdHelper bdHelper;
	public String palavraChave;
	public Sistema sistema;
	
	public ImportaTweets(String palavraChave, BdHelper bdHelper, Sistema sistema)
	{
		twitterHelper = new TwitterHelper();
		this.bdHelper = bdHelper;
		this.palavraChave = palavraChave;
		this.sistema = sistema;
	}

	@Override
	public void run()
	{
	
			while (true)
			{
				importar();
				//bdHelper.filtraTweets(palavraChave);
				try
				{
					sleep(1000 * 60 * 10);
				}
				catch (InterruptedException e)
				{
					//e.printStackTrace();
				}
			}
	}

	public void importar()
	{
		ArrayList<Tweet> tweets;
		long lastId;
		int rank;
		String classificacao;
		String texto;
		String userName;

		lastId = bdHelper.getLastId(palavraChave);
		tweets = twitterHelper.getTweets(palavraChave, lastId);

		for (Tweet t : tweets)
		{
			texto = sistema.tratarTexto(t.getText());
			userName = sistema.tratarTexto(t.getFromUser());
			
			
			rank = sistema.analisaTweet(texto);
			if(rank >0) classificacao = "positivo";
			else if (rank < 0) classificacao = "negativo";
			else classificacao = "neutro";
			
			bdHelper.gravarBanco(t.getId() + "", texto, userName, t.getCreatedAt().toString(), palavraChave, classificacao);
		
		}
		//bdHelper.filtraTweets(palavraChave);
	}




	
}